311d655cd7564f71a49c5d681231351df7de97fd,spring/src/main/java/org/wso2/msf4j/spring/SpringMicroservicesRunner.java,SpringMicroservicesRunner,configureTransport,#Collection#Collection#,107
Before Change
HTTPTransportListener nettyListener = createListenerConfiguration(transportConfig);
registerTransport(nettyListener);
nettyTransportContextHolder
.setMessageProcessor(new MSF4JMessageProcessor(transportConfig.getId(), getMsRegistry()));
}
}
}
After Change
}
//Add NettyTransportConfig if available on Spring Configuration
nettyTransportContextHolder.setMessageProcessor(new MSF4JMessageProcessor());
for (TransportConfig transportConfig : transportConfigs) {
if (transportConfig.isEnabled()) {
HTTPTransportListener nettyListener = createListenerConfiguration(transportConfig);